﻿

<?php

session_start();
header("Content-Type: text/html; charset=utf-8");
include_once( 'config.php' );
include_once( 'weibooauth.php' );



//**************用某个用户的固定token取数据**********************
$a = "707f5c6e978c5cb39e1d883ba9e2705c";
$b = "ec7011db857771d5fdf72530303c9bcb";
$c = new WeiboClient( WB_AKEY , WB_SKEY , $a , $b  );
//**************用某个用户的固定token取数据**********************



//$c = new WeiboClient( WB_AKEY , WB_SKEY , $_SESSION['last_key']['oauth_token'] , $_SESSION['last_key']['oauth_token_secret']  );
$ms  = $c->home_timeline(); // done,   mike：选择类的某个出来方法，本行选择是timeline函授
$me = $c->verify_credentials();

//print_r($ms);  测试使用
echo $me['name'] ."你好~ 要换头像么?";

//××××××××××××××××校验用户列表是否有该用户，若没有就添加一条记录。××××××××××××××××××××××××××××××××
	$name=$me['name']; //由于不能直接用右边的内容，所以用了个变量作为中介。
	$id=$me['id']; 

$con = mysql_connect("localhost", "root","");  


mysql_query("SET NAMES utf8");   //下面3行是解决sql写入写出显示乱码的，详细见http://wenwen.soso.com/z/q104200853.htm
mysql_query("SET CHARACTER SET utf8");
mysql_query("SET COLLATION_CONNECTION='utf8_general_ci'");
if (!$con)
  {
  die('Could not connect: ' . mysql_error());
  }
mysql_select_db("movie3", $con);      //先选择数据库

/* 
 $sql = "SELECT * FROM user WHERE weibo_id='$id'";
 $result = mysql_query($sql,$con);         //执行上面一行的sql
 
 if (mysql_num_rows($result))              //判断是否该用户id存在，即是否有结果记录
  {
  echo "帐号已注册";
  }
  else
   {
  $sql = "INSERT INTO user (weibo_id, name)     
VALUES ( '$id', '$name' )" ;               //若不存在插入用户id
  }
mysql_query($sql,$con); //执行上面语句
*/
//××××××××××××××××校验用户列表是否有该用户，若没有就添加一条记录。××××××××××××××××××××××××××××××××


			
					



//start ××××××××××从数据的电影表，获取电影关键字,放入到临时数组×××××××××××××××××××××××

 $sql = "SELECT * FROM movie WHERE  endtime > unix_timestamp() " ;    // 根据“下影时间”（下影时间晚于当天）过滤出所有电影数据
 $result = mysql_query($sql,$con);         //执行上面一行的sql
 
	 $i=0;
	while( $row=mysql_fetch_array($result) )   //循环取查询结果的每行数据
	{
	  $rows_keyword[$i]=$row;
	  echo "<br/>测试显示电影名" .$rows_keyword[$i][title] ;    //结果为多维数组
	  $i++;
	  $j=$i;  	 //把关键字的个数传递给 变量j，以便后续循环使用
	}
//end×××××××××××从数据的电影表，获取电影关键字,放入到临时数组××××××××××××××××××






//start××××××××××× 刷新微博 转发数、评论数××××××××××××××××××
	for( $i=0; $i<=$j; $i++)   // 从搜索关键字数组里关键字的个数，启动相应次数的循环。
	{	
		$keyword = $rows_keyword[$i][keyword]; //从搜索关键字数组取值
		
		for( $k=0; $k<=10000; $k++ )
		{
		$sql = "SELECT weibo_id FROM comment_new WHERE  DATEDIFF(now(), in_time) < 7 and  TIME_FORMAT( NOW( ) , '%H') - TIME_FORMAT( reflash_time, '%H') >4  or  TIME_FORMAT( NOW( ) , '%H') - TIME_FORMAT( reflash_time, '%H') <-4" ;    //刷新入库时间少于7天，并且4小时内没有刷新过的微博
		$result = mysql_query($sql,$con);  
		echo mysql_num_rows($result). "--23423423423";
	//if ($result) {echo "daf";}
		 if ( mysql_num_rows($result) > 0 )    
		 	{
			//echo  "daf----";
				 $m = 0;
				 $sids = 0;
				 while($row = mysql_fetch_assoc($result))
					{ 
					 $weibo_id[$m] = $row[weibo_id] ;		//取id
					 $sids =  $weibo_id[$m] .",".$sids ;  //把id用逗号隔着合并
					 $m++;
					 if( $m >= 98 ) {break;}   	//取不多于99条数据
					// echo $sids."</br>";
					}					
				 $counts = $c->get_count_info_by_ids( $sids );  	//调用接口
					 if( !is_array( $counts ) )  { echo "-----你可能还没有登录，所有看不到数据-----";  }   //做个判断，看是否调用到接口数据
					// echo print_r($counts);
				 foreach( $counts as $item )     //循环从接口调用的数据
				 	{
						$sql = "update comment_new set rt = '$item[rt]', comments = '$item[comments]', reflash_time = now()
						where weibo_id = '$item[id]'  " ;
						$result = mysql_query($sql,$con); 
						//echo $item[rt]. "</br>" ;
					}					
			}
			else{ break;}   //跳出循环：如果最近7天的微博，在4小时内都已被刷新。
		}
	}


exit;


//若copy，请copy到这里。

 mysql_close($con); ?> 






